package com.weijian.bizmq;

import lombok.RequiredArgsConstructor;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;


@Component
@RequiredArgsConstructor
public class MyMessageProducer {

    final RabbitTemplate rabbitTemplate;

    /**
     * 发送消息的方法
     *
     * @param exchange   交换机名称，指定消息要发送到哪个交换机
     * @param routingKey 路由键，指定消息要根据什么规则路由到相应的队列
     * @param message    消息内容，要发送的具体消息
     */
    public void sendMessage(String exchange, String routingKey, String message) {
        // 使用rabbitTemplate的convertAndSend方法将消息发送到指定的交换机和路由键
        rabbitTemplate.convertAndSend(exchange, routingKey, message);
    }


    public void sendMessage(String message) {
        sendMessage(MqConstant.EXCHANGE_NAME, MqConstant.ROUTING_KEY, message);
    }

}
